package com.surfilter.mq.rocketmq;

public class RocketMqConfig {
	
	private String group;
	
	private String topic;
	//*
	private String tags;
	
	private String namesrvAddr;
	
	private String instanceName;
	
	private int batchSize = 1;
	
	public RocketMqConfig(String group, String topic, String tags, String namesrvAddr, String instanceName,
			int batchSize) {
		super();
		this.group = group;
		this.topic = topic;
		this.tags = tags;
		this.namesrvAddr = namesrvAddr;
		this.instanceName = instanceName;
		this.batchSize = batchSize;
	}

	public String getGroup() {
		return group;
	}

	public void setGroup(String group) {
		this.group = group;
	}

	public String getTopic() {
		return topic;
	}

	public void setTopic(String topic) {
		this.topic = topic;
	}

	public String getTags() {
		return tags;
	}

	public void setTags(String tags) {
		this.tags = tags;
	}

	public String getNamesrvAddr() {
		return namesrvAddr;
	}

	public void setNamesrvAddr(String namesrvAddr) {
		this.namesrvAddr = namesrvAddr;
	}

	public String getInstanceName() {
		return instanceName;
	}

	public void setInstanceName(String instanceName) {
		this.instanceName = instanceName;
	}

	public int getBatchSize() {
		return batchSize;
	}

	public void setBatchSize(int batchSize) {
		this.batchSize = batchSize;
	}
	
	
}
